package com.itheima.rocketmq.rocketmqdemo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class RocketmqDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(RocketmqDemoApplication.class, args);
    }
    /*
    1.创建消息生产者producer，并制定生产者组名
    2.指定Nameserver地址
    3.启动producer
    4.创建消息对象，指定主题Topic、Tag和消息体
    5.发送消息
    6.关闭生产者producer

    1.创建消费者consumer，制定消费者组名
    2.指定Nameserver地址
    3.订阅主题Topic和Tag
    4.设置回调函数，处理消息
    5.启动消费者consumer
    */
}
